package cn.tedu.spring.boot.rabbitmq.consumer;

import cn.tedu.spring.boot.rabbitmq.config.RabbitMQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
//监控rabbitmq中的指定的队列,如果有新消息进入队列，就会调用@RabbitHandler描述的方法
@RabbitListener(queues = RabbitMQConfig.TEST_QUEUE)
public class RabbitConsumer {

    //这个注解只能描述该类中的一个方法
    //把从队列取出的数据转成什么类型进行处理，只需要在方法参数中指定
    @RabbitHandler
    public void process(LocalDateTime now){
        System.out.println("接收到消息是:"+now);
    }
}
